package com.sls.mall.order.rabbit;


import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback;

/**
 * @author lixue
 * @Title: orderConfirmCallback
 * @ProjectName sls_mall2021
 * @Description: TODO
 * @date 2021/5/914:59
 */
public class OrderConfirmCallback implements ConfirmCallback {


    /**
     *
     * @param correlationData  当前消息的唯一关联数据（这个是消息的唯一id）
     * @param akc              消息是否成功收到
     * @param cause            失败的原因
     */
    @Override
    public void confirm(CorrelationData correlationData, boolean akc, String cause) {

        // 成功回调：接收到了orderConfirmCallback回调：CorrelationDataCorrelationData：[null]==>ack[true]==>cause[null]

        System.out.println("接收到了orderConfirmCallback回调：CorrelationDataCorrelationData：["+correlationData+"]==>ack["+akc+"]==>cause["+cause+"]");
    }
}
